package com.Hsu.mq.common;

import lombok.Data;

import java.io.Serializable;

/**
 * @author Hsu琛君珩
 * @ClassName:BasicConsumeArguments
 * @date 2024-03-03
 * @apiNote
 * @Version: v1.0
 */

/**
 * 用于初始化消费者订阅队列时的参数封装
 */
@Data
public class BasicConsumeArguments extends BasicArguments implements Serializable {
    private String consumerTag;
    private String queueName;
    private boolean autoAck;
    //这个类对应的 basicConsume 还有一个参数是回调函数（如何了处理消息）
    //这个回调函数是不能通过网络传输的
    //站在 brokerServer 这边，针对消息的处理回调，其实是统一的（把消息返回给客户端），也就是在服务器这边这个回调是固定的
    //客户端这边收到消息之后，再在客户端自己这边执行一个用户自定义的回调即可，不同的消费者/客户端，这里指定的回调可能都是不同的
    //因此此时客户端不需要把自己要执行的业务回调告诉服务器
    //因此这个类不需要 consumer 这个成员
}
